package com.dy.kafka;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @author dy.huang
 * @date 2020/5/10 23:56
 */
@Component
public class KafkaConfig {

    @KafkaListener(topics = "test")
    public void processMessage(String content) {
        System.out.println("收到消息, topic:test, msg:" + content);
    }

}
